package com.zealfi.wk.service;

import com.zealfi.wk.api.pojo.User;
import rx.Observable;

import java.util.concurrent.Future;

/**
 * Created by kuan at 2018-04-13 下午 3:23
 * 只能消费一次
 */
public interface UserService {

    /**
     * 同步执行
     */
    User getUserById(String id);

    /**
     * 异步执行
     */
    Future<User> getUserByIdAsync(String id);

    Observable<User> getHotObservableUserById(String id);

    Observable<User> getColdObservableUserById(String id);
}
